package com.gzhryc.shared_device.oem.micro.queue.times;

import com.gzhryc.common.logging.Logger;
import com.gzhryc.shared_device.base.enums.EOperatorType;
import com.gzhryc.shared_device.base.models.OperateInfo;
import com.gzhryc.shared_device.common.BusyThreadPool;
import com.gzhryc.shared_device.oem.micro.queue.MicroConstants;
import com.gzhryc.shared_device.oem.micro.queue.work.CDCZCacheFinishCheckRunnable;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

public class Every3MinutesCheckJob implements Job {

    static Logger log = Logger.getLogger(Every3MinutesCheckJob.class);

    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        log.info("设备订单完成检查，每3分钟检查一次");

        OperateInfo operateInfo = new OperateInfo(MicroConstants.PROGRAM_TYPE, MicroConstants.PROGRAM_TYPE_NAME);
        operateInfo.setOperator(EOperatorType.System.index(), "每3分钟定时检查程序");

        BusyThreadPool.self().execute(new CDCZCacheFinishCheckRunnable(operateInfo));
    }
}
